home *** CD-ROM | disk | FTP | other *** search
/ The CICA Windows Explosion! / The CICA Windows Explosion! - Disc 2.iso / demo / igps_102.zip / TALKSOCK.H < prev    next >
C/C++ Source or Header  |  1994-06-23  |  5KB  |  158 lines
  1. ///////////////////////////////////////////////////////////////////////////////////
  2. // Internet Global Phone Project
  3. // talksock.h : declaration of the CTalkClient, CTalkListenServer, and CTalkServer
  4. //              classes
  5. //
  6. // The CTalk... classes implements protocol specific behaviours on top of the
  7. // CSocketOwner, CSockServer, CSockClient, and CSockListenServer base classes.
  8. // See the main text of article in Dr. Dobb's Journal for a discussion of the
  9. // class hierachy.
  10. //
  11. ////////////////////////////////////////////////////////////////////////////////////
  12. // Copyright (c) 1993-1994    microWonders Inc.  All rights reserved.
  13. //                                                                         
  14. // AN OPEN INVITION TO BUILD UPON AND CONTRIBUTE TO THE PUBLIC TECHNOLOGY POOL:
  15. // You are encouraged to redistribute, and build upon the technologies presented 
  16. // in this source module and the accompanying article in Dr. Dobb's Journal provided 
  17. // all the conditions listed in the MUSTREAD.TXT file, included with this 
  18. // distribution, are met.
  19. ////////////////////////////////////////////////////////////////////////////////////
  20.  
  21. // play within limit of an integer, send/receive chunk blocks
  22. // most WINSOCK implementation can only take 32k max at a time anyway
  23. #define DATACHUNKSIZE    16000  
  24. #define SENDSIZE         72323     
  25. #define DONE            999  // third state in additional to TRUE and FALSE
  26.                                             
  27. //
  28. // enumerated protocol states, this is a minor experimentation to see
  29. // if it is somehow possible to generalize and automate the protocol 
  30. // handling process (via code generation).  As of printing deadline,
  31. // experiment still on-going.
  32. //                                            
  33. enum TalkStates {
  34.     S_RESET,
  35.     S_ACK1,
  36.     S_READTYPE,
  37.     S_ACK2,    
  38.     S_READSIZE,
  39.     S_ACK3,    
  40.     S_READDATA,
  41.     S_ACK4
  42.     } ;
  43.     
  44. ///////////////////////////////////////////////////////////////////////////// 
  45. class CPhoneView;          
  46.  
  47. class CTalkServer: public CSocketOwner
  48. {                                
  49. public:
  50.     CTalkServer(); 
  51.     ~CTalkServer();
  52.  
  53.     WSSOCKET StartServer(HWND, NOTIFYPROC);
  54.     WSSOCKET EndServer(WSSOCKET);
  55.     BOOL GetBuffer(void);
  56.     UINT DataRead(void);    
  57.     void SendAck(void);
  58.     virtual void OnOtherMsgs(int, int);
  59.     virtual void OnReceiveCompleted(int, int);
  60.     virtual void OnSendCompleted(int, int);
  61.     virtual void OnDisconnected(int, int);
  62.  
  63. public:  
  64.   CPhoneView * m_PhoneView;
  65. private:  
  66.   WSPORTID    m_uPort;
  67.   WSADDRESS   m_lAddress;
  68.   char        m_szBuffer[DATACHUNKSIZE];
  69.   HGLOBAL      m_hspeechBuffer;    
  70.   HPSTR          m_pBuffer;
  71.   HPSTR          m_pCurBuf; 
  72.   ULONG          m_bufSize;
  73.   UINT          m_compressionType;  
  74.   BOOL          m_speechReady;
  75.   TalkStates  m_state; 
  76.  
  77. #ifdef _DEBUG
  78.     virtual void AssertValid() const;
  79.     virtual void Dump(CDumpContext& dc) const;
  80. #endif
  81.  
  82. }; 
  83.  
  84.  
  85. class CTalkListenServer: public CSockListenServer
  86. {                                
  87. public:
  88.     CTalkListenServer(); 
  89.     ~CTalkListenServer();
  90.     WSSOCKET StartListener(LPCSTR, WSPORTID, LPWSADDRESS, HWND, NOTIFYPROC,  CPhoneView *);
  91.  
  92.     virtual void OnOtherMsgs(int, int);
  93.                                              
  94. protected:
  95.      CPhoneView * m_PhoneView;
  96. #ifdef _DEBUG
  97.     virtual void AssertValid() const;
  98.     virtual void Dump(CDumpContext& dc) const;
  99. #endif
  100.     
  101. };
  102.  
  103. class CTalkClient: public CSocketOwner
  104. { 
  105.  
  106. public: // create from serialization only
  107.     CTalkClient(); 
  108.     ~CTalkClient(); 
  109.     // overload to connect by name or address
  110.     WSSOCKET Connect( UINT prot, WSADDRESS, WSPORTID, UINT, HWND,
  111.      NOTIFYPROC, UINT, HPSTR, ULONG);
  112.     BOOL SetTimeout(WSSOCKET, UINT);
  113.     BOOL End();
  114.  
  115.     UINT SendData(void); 
  116.     void GetAck(void); 
  117.     
  118.     virtual void OnConnected(int, int);
  119.     virtual void OnSendCompleted(int, int);
  120.     virtual void OnReceiveCompleted(int, int);
  121.     virtual void OnTimerExpired(int, int);       
  122.     virtual void OnDisconnected(int, int);
  123.  
  124. private:  
  125.   BOOL        m_bConnected;
  126.   WSADDRESS   m_lAddress;
  127.   // some legacy variables from performance statistic gathering
  128.   WSPORTID    m_uPort;
  129.   WSADDRESS   m_lRecvAddress;
  130.   WSPORTID    m_uRecvPort;
  131.   UINT        m_uAttempts;
  132.   UINT        m_uFailures;
  133.   DWORD       m_dMin;
  134.   DWORD       m_dAvg;
  135.   DWORD       m_dMax;
  136.   long double m_ldTotalTime;
  137.   UINT        m_uSequence;     
  138.   BOOL        m_bInProgress;
  139.   UINT        m_uInterval;
  140.   UINT        m_uLateReplies;
  141.   UINT        m_uLimit;
  142.  
  143.   UINT        m_uErrorCount;
  144.   ECHOPACKET  m_Packet;
  145.  
  146.   HPSTR            m_talkBuffer;    
  147.   HPSTR          m_pCurBuf;  // sliding pointer for 'chunk' sending
  148.   ULONG          m_bufLen;  
  149.   char          m_szBuffer[WSTALKBUFFERSIZE];
  150.   TalkStates  m_state;   
  151.   UINT          m_lastSentSize;
  152. #ifdef _DEBUG
  153.     virtual void AssertValid() const;
  154.     virtual void Dump(CDumpContext& dc) const;
  155. #endif
  156.  
  157. };
  158.